//package com.imooc.bilibili.util;
//
//
//import org.apache.rocketmq.client.producer.DefaultMQProducer;
//import org.apache.rocketmq.client.producer.SendCallback;
//import org.apache.rocketmq.client.producer.SendResult;
//import org.apache.rocketmq.common.message.Message;
//import org.slf4j.Logger;
//import org.slf4j.LoggerFactory;
//
//public class RocketMQUtil {
//
//    /**
//     * 同步发送消息
//     */
//    public static void syncSendMsg(DefaultMQProducer producer, Message msg) throws Exception {
//        SendResult result = producer.send(msg);
//        System.out.println("发送结果：" + result);
//    }
//
//    /**
//     * 异步发送消息(如果对发送消息的回调不关心，那么可以用异步发送；否则就用同步发送)
//     */
//    public static void asyncSendMsg(DefaultMQProducer producer, Message msg) throws Exception {
//        producer.send(msg, new SendCallback() {
//            /**
//             * 发送消息成功，执行回调方法
//             * */
//            @Override
//            public void onSuccess(SendResult sendResult) {
//                Logger logger = LoggerFactory.getLogger(RocketMQUtil.class);
//                logger.info("异步发送消息成功，消息id：" + sendResult.getMsgId());
//            }
//
//            /**
//             * 发送消息失败，输出异常
//             * */
//            @Override
//            public void onException(Throwable e) {
//                Logger logger = LoggerFactory.getLogger(RocketMQUtil.class);
//                logger.info("异步发送消息失败，消息id：" + e.toString());
//                e.printStackTrace();
//            }
//        });
//    }
//}
